//package com.scgk.sync.controller;
//
//import cn.hutool.core.date.DateUtil;
//import cn.hutool.core.util.IdUtil;
//import com.scgk.sync.common.BaseResponse;
//import com.scgk.sync.common.utils.SftpClientUtil;
//import com.scgk.sync.doamin.Lrrk;
//import com.scgk.sync.service.ILrrkService;
//import io.swagger.annotations.Api;
//import io.swagger.annotations.ApiOperation;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.*;
//
//import java.util.*;
//
//@Api(value = "流入人口", tags = "流入人口")
//@Slf4j
//@RestController
//@RequestMapping("/lrrk")
//public class LrrkController {
//
//    @Autowired
//    private ILrrkService iLrrkService;
//
//
//    @ApiOperation("解析行政当前流入人口文件")
//    @GetMapping("/lrrkByMore")
//    public BaseResponse lrrkByMore() {
//        List<Lrrk> records = new ArrayList<Lrrk>();
//        try {
//            SftpClientUtil instans = SftpClientUtil.getInstans("192.168.10.1", "test", "test", 220, "UTF-8");
//            List<String> stringList = instans.getFilesDates("/", "F:\\demo\\");
//            stringList.stream().forEach(item ->{
//                String[] arrStrings = item.split(","); // 用于把一个字符串分割成字符串数组
//                Lrrk build = Lrrk.builder()
//                        .id(IdUtil.simpleUUID())
//                        .zd1(arrStrings[0])
//                        .zd2(arrStrings[1])
//                        .zd3(arrStrings[2])
//                        .zd4(arrStrings[3])
//                        .zd5(arrStrings[4])
//                        .zd6(arrStrings[5])
//                        .indate(DateUtil.date().toString())
//                        .build();
//                records.add(build);
//            });
//
//        } catch (Exception e) {
//            System.out.println("文件读取错误!");
//        }
//
//        if (records != null && records.size() > 0) {
//            iLrrkService.saveBatch(records);
//        }
//
//        return BaseResponse.ok();
//    }
//
//
//    //@ApiOperation("解析行政当前流入人口文件")
//    //@GetMapping("/lrrk")
//    //public BaseResponse readRechargeWithdrawTxt() {
//    //	List<Lrrk> records = new ArrayList<Lrrk>();
//    //
//    //	// 从SFTP服务器下载的txt文件
//    //	File file = new File("F:\\sftp_dir\\lrrk.txt");
//    //
//    //	try {
//    //		if (file.isFile() && file.exists()) {
//    //			InputStreamReader isr = new InputStreamReader(new FileInputStream(file), "utf-8");
//    //			BufferedReader buffReader  = new BufferedReader(isr);
//    //
//    //			String  line="";
//    //			StringBuilder resultStringBuilder = new StringBuilder();
//    //			while ((line = buffReader.readLine()) != null) {
//    //				// 读取每一行数据
//    //				resultStringBuilder.append(line).append("\n");
//    //				log.info("每行数据:{}",line);
//    //
//    //				String[] arrStrings = line.split(","); // 用于把一个字符串分割成字符串数组
//    //				Lrrk build = Lrrk.builder()
//    //						.id(IdUtil.simpleUUID())
//    //						.zd1(arrStrings[0])
//    //						.zd2(arrStrings[1])
//    //						.zd3(arrStrings[2])
//    //						.zd4(arrStrings[3])
//    //						.zd5(arrStrings[4])
//    //						.zd6(arrStrings[5])
//    //						.indate(DateUtil.date().toString())
//    //						.build();
//    //
//    //				// 用set方法将取值分别添加到对应字符串数组 ，用add方法存入list
//    //				records.add(build);
//    //			}
//    //			buffReader .close();
//    //
//    //		} else {
//    //			System.out.println("文件不存在!");
//    //		}
//    //	} catch (Exception e) {
//    //		System.out.println("文件读取错误!");
//    //	}
//    //
//    //	if(records!=null &&records.size()>0){
//    //		iLrrkService.saveBatch(records);
//    //	}
//    //
//    //	return BaseResponse.ok();
//    //}
//
//
//    @ApiOperation("从SFTP服务器下载文件")
//    @GetMapping("/filesDownloadInputStream")
//    public BaseResponse filesDownloadInputStream() {
//        try {
//            SftpClientUtil instans = SftpClientUtil.getInstans("127.0.0.1", "test", "test", 22, "UTF-8");
//            List<String> inputStreams = instans.downloadFilesInputStream("/", "F:\\demo\\");
//            instans.disconnect();
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//        return BaseResponse.ok();
//    }
//
//
//    @ApiOperation("上传文件至SFTP服务器")
//    @GetMapping("/filesUpload")
//    public BaseResponse filesUpload() {
//        try {
//            SftpClientUtil instans = SftpClientUtil.getInstans("127.0.0.1", "test", "test", 22, "UTF-8");
//            boolean b = instans.uploadFile("/", "lrrk.txt", "F:\\demo\\", "行政区当前流入人口.txt");
//            instans.disconnect();
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//        return BaseResponse.ok();
//    }
//
//
//    //@ApiOperation("从SFTP服务器下载文件")
//    //@GetMapping("/filesDownload")
//    //public BaseResponse filesDownload(){
//    //	try {
//    //		SftpClientUtil instans = SftpClientUtil.getInstans("127.0.0.1","test","test",22,"UTF-8");
//    //		List<String> strings = instans.downloadFiles("/", "F:\\demo\\");
//    //		instans.disconnect();
//    //	} catch (Exception e) {
//    //		e.printStackTrace();
//    //	}
//    //	return BaseResponse.ok();
//    //}
//
//
//}